package com.iot.mqtt;

import com.iot.ruler.caster.RulerSubject;
import lombok.Getter;

/**
 * @author lzb22
 */
@Getter
public class MessageCallBackSubject extends RulerSubject<Object> {

    private final String topic;
    private final int qos;

    public MessageCallBackSubject(Object source, String topic, int qos) {
        super(source);
        this.topic = topic;
        this.qos = qos;
    }
}
